# -*- coding: utf-8 -*-
from airflow.operators.python import PythonOperator
from .dws_whole_network_aging import main
from jms.doris.jms_dwd.dwd_waybill_prescription_reach_details import \
    doris_jms_dwd__dwd_waybill_prescription_reach_details

doris_jms_dws__dws_whole_network_aging = PythonOperator(
    task_id='doris_jms_dws__dws_whole_network_aging',
    email=['suning@jtexpress.com','yl_bigdata@yl-scm.com'],
    pool='unlimited_pool',
    python_callable=main,
    op_args=['{{ execution_date | cst_ds }}', '{{ var.json.dorsi_jdbc_pas }}'],
)

doris_jms_dws__dws_whole_network_aging << [doris_jms_dwd__dwd_waybill_prescription_reach_details]
